/*****************酒店民宿路由器**********************/
const express = require('express')
const pool = require('../pool.js')
const router = express.Router()
module.exports = router

//1.添加一个查询所有酒店民宿分类的接口
//GET /showClass
//请求地址：http://127.0.0.1:8080/v1/hotel/Class
router.get('/Class',(req,res)=>{
	let sql = 'select cname from hotel_class'
	pool.query(sql,(err,result)=>{
		if(err) throw err
		res.send(result)
	})
})

//2.添加一个查询所有酒店民宿的接口
//GET /show
//测试地址：http://127.0.0.1:8080/v1/hotel/show
router.get('/show',(req,res)=>{
	let sql = 'select * from hotel'
	pool.query(sql,(err,result)=>{
		if(err) throw err
		res.send(result)
	})
})

//3.添加一个查询指定数量酒店民宿的接口
//GET /list
//请求参数 pageSize=3
//测试地址：http://127.0.0.1:8080/v1/hotel/list?pageSize=3
router.get('/list',(req,res)=>{
	let ps = req.query.pageSize
	ps = ps?parseInt(ps):5
	let sql = 'select * from hotel limit ?'
	pool.query(sql,ps,(err,result)=>{
		if(err) throw err
		res.send(result)
	})
})

//4.添加一个某种分类的所有酒店的接口
//GET /classShow
//请求参数 hotel_class_id=1            1-酒店住宿  2-渔农家乐  3-东海人家
//测试地址：http://127.0.0.1:8080/v1/hotel/classShow?hotel_class_id=1   
router.get('/classShow',(req,res)=>{
	let id = req.query.hotel_class_id
	id = id?parseInt(id):1
	let sql = 'select * from hotel where hotel_class_id=?'
	pool.query(sql,id,(err,result)=>{
		if(err) throw err
		res.send(result)
	})
})

//5.查询酒店地址中含有某个词（比如临城）的酒店民宿的接口
//GET /adressShow
//请求参数:string=临城
//测试地址：http://127.0.0.1:8080/v1/hotel/adressShow?string=临城
router.get('/adressShow',(req,res)=>{
	let str = req.query.string
	if(!str){
		res.send({code:201,msg:'搜索内容不能为空'})
		return
	}
	let sql = `select * from hotel where hotel_address like "%${str}%"`
	pool.query(sql,str,(err,result)=>{
		if(err) throw err
		res.send(result)
	})
})

//6.用户添加评论的接口
//POST /add_review
//请求主体：hotel_name=舟山喜来登绿城酒店&review=环境不错
//测试地址：http://127.0.0.1:8080/v1/hotel/add_review
router.post('/add_review',(req,res)=>{
	let name = req.body.hotel_name
	let review = req.body.review
	if(!name){
		res.send({code:201,msg:'酒店名称不能为空！'})
	}
	if(!review){
		res.send({code:201,msg:'内容不能为空！'})
		return
	}
	let sql = 'insert into hotel(hotel_name,review) values(?,?)'
	pool.query(sql,[name,review],(err,result)=>{
		if(err) throw err
		res.send({code:200,msg:'添加成功'})
	})
	
})







